package test.serverframe.armc.server.manager.service.exec.params;

import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

import test.serverframe.armc.server.manager.service.exec.dag.DagNode;

/**
 * 接口执行参数
 *
 * @author LiuChunfu
 * @date 2019.01.19
 */
public class InterfaceExecutorParams {

	//nodeId维护接口的父子关系，此nodeId与taskId确定接口的唯一参数
    private String nodeId;
    
    private String taskId;
    
    //接口执行成功总数
    private AtomicInteger successInterfaceTotal;
    
    //接口执行总数
    private AtomicInteger interfaceTotal;
    
    //任务执行总数
    private AtomicInteger taskTotal;
    
    //任务执行成功总数
    private AtomicInteger successTaskTotal;

    private int expectedTaskTotal;

	private int expectedInterfaceTotal;

	//任务记录主键id
    private String taskRecordId;

    private String invokeRecordId;

    private Map<String,String> cache;
    
    private DagNode interfaceDagNode;
    
    private DagNode taskDagNode;
    
    private String failedStrategy;
    
    private String taskInvokeId;
    
    private Boolean isReStart;
    
	public String getNodeId() {
		return nodeId;
	}

	public void setNodeId(String nodeId) {
		this.nodeId = nodeId;
	}

	public String getTaskId() {
		return taskId;
	}

	public void setTaskId(String taskId) {
		this.taskId = taskId;
	}

	public AtomicInteger getSuccessInterfaceTotal() {
		return successInterfaceTotal;
	}

	public void setSuccessInterfaceTotal(AtomicInteger successInterfaceTotal) {
		this.successInterfaceTotal = successInterfaceTotal;
	}

	public AtomicInteger getInterfaceTotal() {
		return interfaceTotal;
	}

	public void setInterfaceTotal(AtomicInteger interfaceTotal) {
		this.interfaceTotal = interfaceTotal;
	}

	public AtomicInteger getTaskTotal() {
		return taskTotal;
	}

	public void setTaskTotal(AtomicInteger taskTotal) {
		this.taskTotal = taskTotal;
	}

	public AtomicInteger getSuccessTaskTotal() {
		return successTaskTotal;
	}

	public void setSuccessTaskTotal(AtomicInteger successTaskTotal) {
		this.successTaskTotal = successTaskTotal;
	}

	public String getTaskRecordId() {
		return taskRecordId;
	}

	public void setTaskRecordId(String taskRecordId) {
		this.taskRecordId = taskRecordId;
	}

	public int getExpectedTaskTotal() {
		return expectedTaskTotal;
	}

	public void setExpectedTaskTotal(int expectedTaskTotal) {
		this.expectedTaskTotal = expectedTaskTotal;
	}

	public int getExpectedInterfaceTotal() {
		return expectedInterfaceTotal;
	}

	public void setExpectedInterfaceTotal(int expectedInterfaceTotal) {
		this.expectedInterfaceTotal = expectedInterfaceTotal;
	}

	public String getInvokeRecordId() {
		return invokeRecordId;
	}

	public void setInvokeRecordId(String invokeRecordId) {
		this.invokeRecordId = invokeRecordId;
	}

	public Map<String, String> getCache() {
		return cache;
	}

	public void setCache(Map<String, String> cache) {
		this.cache = cache;
	}

	public DagNode getInterfaceDagNode() {
		return interfaceDagNode;
	}

	public void setInterfaceDagNode(DagNode interfaceDagNode) {
		this.interfaceDagNode = interfaceDagNode;
	}

	public DagNode getTaskDagNode() {
		return taskDagNode;
	}

	public void setTaskDagNode(DagNode taskDagNode) {
		this.taskDagNode = taskDagNode;
	}
	
	public String getFailedStrategy() {
		return failedStrategy;
	}

	public void setFailedStrategy(String failedStrategy) {
		this.failedStrategy = failedStrategy;
	}

	public String getTaskInvokeId() {
		return taskInvokeId;
	}

	public void setTaskInvokeId(String taskInvokeId) {
		this.taskInvokeId = taskInvokeId;
	}

	public Boolean getIsReStart() {
		return isReStart;
	}

	public void setIsReStart(Boolean isReStart) {
		this.isReStart = isReStart;
	}

}
